//package cn._51doit.day05.hbaseReduce;
//import org.apache.hadoop.conf.Configuration;
//import org.apache.hadoop.hbase.Cell;
//import org.apache.hadoop.hbase.CellUtil;
//import org.apache.hadoop.hbase.HBaseConfiguration;
//import org.apache.hadoop.hbase.TableName;
//import org.apache.hadoop.hbase.client.*;
//
///**
// * @create: 2021-10-21 09:56
// * @author: 今晚打脑斧
// * @program: HbaseUtil
// * @Description:
// **/
//public class HbaseUtil{
//    /**
//     * 获取hbase的连接对象
//     * @return
//     * @throws Exception
//     */
//    public static Connection getConnection() throws  Exception{
//        Configuration conf = HBaseConfiguration.create();
//        // 设置zk的地址
//        conf.set("hbase.zookeeper.quorum" , "doit01:2181,doit02:2181,doit03:2181");
//        // 获取连接对象
//        Connection conn = ConnectionFactory.createConnection(conf);
//        return conn ;
//    }
//
//    /**
//     * 获取Admin
//     * @return
//     * @throws Exception
//     */
//    public static Admin getAdmin() throws  Exception{
//        Configuration conf = HBaseConfiguration.create();
//        // 设置zk的地址
//        conf.set("hbase.zookeeper.quorum" , "doit01:2181,doit02:2181,doit03:2181");
//        // 获取连接对象
//        Connection conn = ConnectionFactory.createConnection(conf);
//        return conn.getAdmin() ;
//    }
//
//    /**
//     * 根据表名 获取表对象
//     * @param tbName
//     * @return
//     * @throws Exception
//     */
//    public static Table getTable(String tbName) throws  Exception{
//        Configuration conf = HBaseConfiguration.create();
//        // 设置zk的地址
//        conf.set("hbase.zookeeper.quorum" , "doit01:2181,doit02:2181,doit03:2181");
//        // 获取连接对象
//        Connection conn = ConnectionFactory.createConnection(conf);
//        Table table = conn.getTable(TableName.valueOf(tbName));
//        return  table ;
//    }
//
//    /**
//     * 读取数据,并打印用的工具类
//     * @param result()
//     */
//    public  static  void showData(Result result){
//        while(result.advance()){ // 判断是否有下一个单元格
//            // 有单元格  获取当前的单元格
//            Cell cell = result.current();
//            // 在Hbase底层存储的数据都是字节数组 , 内部有统一的数据处理方式
//            byte[] cf = CellUtil.cloneFamily(cell);
//            byte[] qualifier = CellUtil.cloneQualifier(cell);
//            byte[] value = CellUtil.cloneValue(cell);
//            byte[] cloneRow = CellUtil.cloneRow(cell);
//            System.out.println(
//                    new String(cloneRow)+"---"+
//                            new String(cf)+"----"+
//                            new String(qualifier)+"----"+
//                            new String(value)
//            );
//        }
//    }
//
//}
